package css.sword.annotation.kafka;



/**
 * 缓存对象
 * @author liboyang
 *
 */
public abstract class OAKafkaAbs {

    /**
     * DEFAULT_TIMEOUT
     */
    public static final int DEFAULT_TIMEOUT = 100000;

    /**
     * commands
     */
    protected OAKafkaCommands commands;

    /**
     *@constructor 构造方法

     */
    protected OAKafkaAbs() throws Exception {
        try {
            init();
        } catch (Exception e) {
            throw new Exception("100001:缓存初始化失败", e);
        }
    }

    /**
     * 初始化
     * @throws Exception
     */
    protected abstract void init() throws Exception;

    /**
     * 获取指令接口
     * @return 12
     */
    public OAKafkaCommands getCommands() {
        return this.commands;
    }
}
